package day17.udp2;

import lombok.SneakyThrows;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;

public class Server {
    @SneakyThrows
    public static void main(String[] args) {
        // 创建服务器对象，并监听在9527端口
        try (DatagramSocket datagramSocket = new DatagramSocket(9527)) {
            while (true) {
                // 等待别人给我发消息，阻塞等待
                String message = UdpUtils.receiveMessage(datagramSocket);
                if ("byebye".equals(message)) break;
                System.out.println("[9527端收到消息]：" + message);
                // 提示用户输入内容
                String inputMessage = UdpUtils.input();
                // 发送数据
                UdpUtils.sendMessage(datagramSocket, inputMessage, UdpUtils.buildAddress(9528, "127.0.0.1"));
            }
        }
    }
}
